package com.song.shop.rocketmq;

import org.apache.rocketmq.common.message.MessageExt;
import org.springframework.stereotype.Component;

/**
 * Created by IntelliJ IDEA.
 *
 * @author: Song Yinhui
 * @Date: 2018/12/7 17:38
 */
@Component
public class TestCustomer implements ICustomerCallBack {
    @Override
    public String getTopic() {
        return "songtopic";
    }

    @Override
    public void process(MessageExt msg) {
        System.out.println("Test处理Mq消息，"+ new String(msg.getBody()));
    }
}
